package com.transaction.demo.message.mq;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Service
@RocketMQMessageListener(consumerGroup = "pay",topic = "test2")
public class RocketMQConsumerListener implements RocketMQListener<String> {
	@Override
	public void onMessage(String s) {
		log.info("消费消息1{}",s);
	}
}